package com.shiku.delayjob.producer;

import com.shiku.delayjob.model.DelayJob;


/**
 * 提交任务接口
 */
public interface ISubmitJobService {

    /**
     * 提交延时任务
     * @param job
     * @param delay
     */
    public boolean submitJob(DelayJob job, Long delay);


    /**
     * 取消延时任务
     * @param jobId
     */
    public boolean cancelDelayJob(String topic,String jobId);


}
